package com.ykht.proj.coupon.mq;

import cn.hutool.json.JSONUtil;
import com.ykht.proj.comsrv.constant.ComConstant;
import com.ykht.proj.comsrv.vo.SubscribeMsgActivityNotice;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;


//@Component
public class Mq {

//	@Slf4j
//	@Component
//	@RocketMQMessageListener(topic = ComConstant.SUBSCRIBE_MSG_TOPIC, consumerGroup = ComConstant.SUBSCRIBE_MSG_ACTIVITY_NOTICE_GROUP, selectorExpression = ComConstant.SUBSCRIBE_MSG_ACTIVITY_NOTICE)
//	public static class ActivityNoticeComsumer implements RocketMQListener<SubscribeMsgActivityNotice> {
//		@Override
//		public void onMessage(SubscribeMsgActivityNotice msg) {
//			log.info("活动接收消息{}", JSONUtil.toJsonStr(msg));
//		}
//	}
}
